package io.github.dunwu.javacore.jdk8.concurrent;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.locks.ReentrantLock;
import java.util.stream.IntStream;

/**
 * @author Benjamin Winterberg
 */
public class Lock1 {

	private static final int NUM_INCREMENTS = 10000;

	private static ReentrantLock lock = new ReentrantLock();

	private static int count = 0;

	public static void main(String[] args) {
		testLock();
	}

	private static void testLock() {
		count = 0;

		ExecutorService executor = Executors.newFixedThreadPool(2);

		IntStream.range(0, NUM_INCREMENTS).forEach(i -> executor.submit(Lock1::increment));

		ConcurrentUtils.stop(executor);

		System.out.println(count);
	}

	private static void increment() {
		lock.lock();
		try {
			count++;
		} finally {
			lock.unlock();
		}
	}

}
